package com.yan;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;

/**
 * TODO
 *
 * @Author: 汪焰
 * @Date: 2021/7/6 22:38
 */
@Component
public class RabbitMQMessageListener {

    /**
     * @PayLoad 注解方法参数，该参数的值就是消息体
     * @Header 注解方法参数，访问指定的消息头字段的值
     * @Headers 该注解的方法参数获取该消息的消息头的所有字段，参数类型对应与map集合
     * MessageHeaders 参数类型 访问所有消息头字段
     * MessageHeaderAccessor or AmqpMessageHeaderAccessor 访问所有消息头字段
     * @Author: 汪焰
     * @Date: 2021/7/6 22:44
     */
//    @RabbitListener(queues = "queue.anno.name.yan")
//    public void onMessage(Message message)throws Exception{
//          String msg=new String(message.getBody(),message.getMessageProperties().getContentEncoding());
//           System.out.println("-----RabbitMQMessageListener--------onMessage-------" + msg);
//    }
    @RabbitListener(queues = "queue.anno.name.yan")
    public void onMessage(@Payload String message) throws Exception {
        System.out.println("-----RabbitMQMessageListener--------onMessage-------" + message);
    }
}
